package dataStruct.queue.ex4;

import dataStruct.queue.ex3.MsgBody;
import dataStruct.queue.ex3.MsgTable;
import dataStruct.queue.ex3.State;
import dataStruct.queue.ex3.ThreadMsgInfo;

import java.util.Calendar;
import java.util.HashMap;
import java.util.Queue;

/**
 * Created by thinkpad on 2016/9/15.
 */
public class Scheduler implements Runnable {
    private Queue<MsgBody> msgQueue;
    private MsgTable msgTable;

    public Scheduler(Queue<MsgBody> msgQueue, MsgTable msgTable, HashMap<Long, ThreadMsgInfo> threadMsgInfoHashMap) {
        this.msgQueue = msgQueue;
        this.msgTable = msgTable;
        this.threadMsgInfoHashMap = threadMsgInfoHashMap;
    }

    private HashMap<Long, ThreadMsgInfo> threadMsgInfoHashMap;
    public Scheduler(Queue<MsgBody> msgQueue, MsgTable msgTable) {
        this.msgQueue = msgQueue;
        this.msgTable = msgTable;
    }

    @Override
    public void run() {
        System.out.println("Scheduler---" + Thread.currentThread() + "---msgQueue.size():" + msgQueue.size());
    }

    void delay(int outCount, int inCount) {
        for(int i = 0; i < outCount;i++){
            for(int j = 0; j < outCount;j++){
            }
        }
    }
}
